2b1e214e5e2fb1190bf72f5970bd7a77c3358d48,conduit-worker/src/main/java/com/inmobi/conduit/Conduit.java,Conduit,copyAuditUtilJarToClusterFs,#Cluster#String#,240
Before Change
// copy AuditUtil source jar into /conduit/system/tmp/jars path
Path AuditUtilJarDestPath = new Path(jarsPath, "messaging-client-core.jar");
if (!clusterFS.exists(AuditUtilJarDestPath)) {
clusterFS.copyFromLocalFile(new Path(auditUtilSrcJar), AuditUtilJarDestPath);
}
}
After Change
if (clusterFS.exists(AuditUtilJarDestPath)) {
clusterFS.delete(AuditUtilJarDestPath, true);
}
clusterFS.copyFromLocalFile(new Path(auditUtilSrcJar), AuditUtilJarDestPath);
}
protected LocalStreamService getLocalStreamService(ConduitConfig config,